Я работаю с оператором повтора в RxSwift. Согласно документации, он «повторно подписывается» на наблюдаемый источник при обнаружении ошибки. Это все хорошо. Однако я не совсем уверен, как рассуждать о «наблюдаемом источнике», когда он содержит горячие наблюдаемые или смесь горячих / холодных наблюдаемых. Пример, в котором я уверен: let coldObservable = Observable.instance (.seconds (1), scheduler: MainScheduler.instance) let coldObservableRetry = coldObservable.flatMapLatest {число в если число% 3 == 0 {return .just (число)} else {return .error ()} } .retry (2) // повторная попытка включает исходную попытку coldObservableRetry.subscribe (onNext: {print ($ 0)}) // печатает 1, 2, 1, 2 перед ошибкой. Пример, в котором я не уверен: let hotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .publish (). connect () let hotObservableRetry = hotObservable.flatMapLatest {число в if num% 3 == 0 {return .just (num)} else {return .error ()} } .retry (2) hotObservableRetry.subscribe (onNext: {print ($ 0)}) // Что здесь происходит? Другой пример, в котором я не уверен: let coldObservable = Observable .instance (.seconds (1), scheduler: MainScheduler.instance) let delayedHotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .delay (.milliseconds (100), scheduler: MainScheduler.instance) .publish (). connect () let mixObservableRetry = Observable.combineLatest (coldObservable, delayedHotObservable) .map {$ 0 + $ 1} .flatMapLatest {число в if num% 3 == 0 {return .just (num)} else {return .error ()} } .retry (5) MixObservableRetry.subscribe (onNext: {print ($ 0)}) // Что здесь происходит? Что вообще означает повторная подписка на combLatest с горячим и холодным наблюдаемым? Еще один пример, в котором я не уверен: let coldObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) let hotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .publish (). connect () let mixObservable2Retry = coldObservable.flatMapLatest {_ в hotObservable} .flatMapLatest {число в if num% 3 == 0 {return .just (num)} else {return .error ()} } .retry (2) MixObservable2Retry.subscribe (onNext: {print ($ 0)}) // Что здесь происходит?
2021-02-26 08:18:13
Многие из ваших примеров не компилируются, поэтому происходит ошибка компиляции. :-) Но чтобы ответить на заданный вопрос ...
Следует помнить о некоторых важных вещах.
Каждый оператор подписывается на свои исходные наблюдаемые объекты и генерирует новые наблюдаемые.
Когда холодный наблюдаемый объект подписан, он будет генерировать 0 ... N следующих событий, а затем событие остановки (которое либо завершено, либо ошибка). Он предоставит каждой подписке свой собственный набор событий.
Горячие наблюдаемые не начинают излучать, пока не будет вызвано их соединение. Все подписки будут иметь один и тот же набор событий.
Наконец, в этом случае отладка - ваш друг.
Итак, для вашего первого примера вы не уверены (настроено так, чтобы он компилировался и запускался с добавлением некоторых операторов отладки):
func example () {
let hotObservable = Observable .instance (.seconds (1), scheduler: MainScheduler.instance)
.debug ("перед публикацией")
.публиковать()
пусть hotObservableRetry = hotObservable
.debug ("после публикации")
.map {(число) -> Int в
номер защиты% 3! = 0 иначе {throw MyError ()}
вернуть номер
}
.debug ("после карты")
.retry (2)
.debug ("после повторной попытки")
_ = hotObservableRetry.subscribe ()
_ = hotObservable.connect ()
}
Будет произведен вывод ниже.
Вот некоторые вещи, которые следует отметить в результате, которые помогут в процессе обучения.
Подписка происходит в обратном порядке.
После появления первой ошибки оператор повтора повторно подписывается на наблюдаемый объект оператора карты, который повторно подписывается на наблюдаемый объект публикации. Поскольку наблюдаемая публикация является горячей, цепочка повторной подписки на этом останавливается. Подписка на наблюдаемую таймером не возобновляется.
Выше приведены ключевые моменты, которые необходимо понять, чтобы ответить на этот вопрос.
после повтора -> подписан
после карты -> подписан
после публикации -> подписался
перед публикацией -> подписался
перед публикацией -> Следующее событие (0)
после публикации -> Следующее событие (0)
после карты -> Ошибка события (MyError ())
после карты -> isDisposed
после публикации -> isDisposed
после карты -> подписан
после публикации -> подписался
перед публикацией -> Следующее событие (1)
после публикации -> Следующее событие (1)
после карты -> Следующее событие (1)
после повтора -> Следующее событие (1)
перед публикацией -> Следующее событие (2)
после публикации -> Следующее событие (2)
после карты -> Следующее событие (2)
после повтора -> Следующее событие (2)
перед публикацией -> Следующее событие (3)
после публикации -> Следующее событие (3)
после карты -> Ошибка события (MyError ())
после повторной попытки -> Ошибка события (MyError ())
после повторной попытки -> isDisposed
после карты -> isDisposed
после публикации -> isDisposed
перед публикацией -> Следующее событие (4)
перед публикацией -> Следующее событие (5)
перед публикацией -> Следующее событие (6)
...
В следующем примере, который вы показали, оператор combLatest повторно подписывается на горячий наблюдаемый объект, но подключаемый наблюдаемый объект не подписывается повторно на его источник.
7
|
Твой ответ
StackExchange.ifUsing ("редактор", function () {
StackExchange.using ("externalEditor", function () {
StackExchange.using ("сниппеты", function () {
StackExchange.snippets.init ();
});
});
}, "фрагменты кода");
StackExchange.ready (функция () {
var channelOptions = {
теги: "" .split (""),
id: "1"
};
initTagRenderer ("". split (""), "" .split (""), channelOptions);
StackExchange.using ("externalEditor", function () {
// Нужно запускать редактор после сниппетов, если сниппеты включены
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using ("сниппеты", function () {
createEditor ();
});
}
еще {
createEditor ();
}
});
function createEditor () {
StackExchange.prepareEditor ({
useStacksEditor: ложь,
heartbeatType: 'ответ',
autoActivateHeartbeat: ложь,
convertImagesToLinks: правда,
noModals: правда,
showLowRepImageUploadWarning: true,
РепутацияToPostImages: 10,
bindNavPrevention: правда,
постфикс: "",
imageUploader: {
brandingHtml: "На основе \ u003ca href = \" https: //imgur.com/ \ "\ u003e \ u003csvg class = \" svg-icon \ "width = \" 50 \ "height = \" 18 \ "viewBox = \ "0 0 50 18 \" fill = \ "none \" xmlns = \ "http: //www.w3.org/2000/svg \" \ u003e \ u003cpath d = \ "M46.1709 9.17788C46.1709 8.26454 46.2665 7.94324 47.1084 7.58816C47.4091 7.46349 47.7169 7.36433 48.0099 7.26993C48.9099 6.97997 49.672 6.73443 49.672 5.93063C49.672 5.22043 48.9832 4.61182 48.1414 4.61182C47.4335 4.61182 46.725623.40716284,61182C47.4335 4.61182 46.725623.4623.68 43.1481 6.59048V11.9512C43.1481 13.2535 43.6264 13.8962 44.6595 13.8962C45.6924 13.8962 46.1709 13.2535 46.1709 11.9512V9.17788Z \ "/ \ u003e \ u003cpath d = \" M32.492 10.1419954.037.048.037.048.037.048.037.048.0 148.48.94.492.492.492 10.14194.0 148.048.0 148.048.0 148.48.95.0 148.048.0 148.48.0 148.048.0 148.048.0 148.048.0 148.048.0 37.048.0 37.048.0 37.0 48.48.0 148.48.0 148.48.0/148.48.0 41.5985 12.6954 41.5985 10.1419V6.59049C41.5985 5.28821 41.1394 4.66232 40.1061 4.66232C39.0732 4.66232 38.5948 5.28821 38.5948 6.59049V9.60062C38.5948 10.8521 38.2696 11.5455 37.0451 11.5454.595 1045820 35.820 521 35.4954 9.60062V6.59049C35.4954 5.28821 35.0173 4.66232 34.0034 4.66232C32.9703 4.66232 32.492 5.28821 32.492 6.59049V10.1419Z \ "/> \ u003cpath fill-rule = \" evenodd \ "clip-rule = \" evenodd \ " = \ "M25.6622 17.6335C27.8049 17.6335 29.3739 16.9402 30.2537 15.6379C30.8468 14.7755 30.9615 13.5579 30.961511.9512V6.59049C30.9615 5.28821 30.4833 4.66231 29.4502 4.66231C28.9913 4.66231 28.4555 4.94978 28.1109 5.50789C27.499 4.86533 26.7335 4.56087 25.7005 4.56087C23.1369 4.56087 21.0134 6.5713.232.0 13328.49 13328.48.92.0134 6.571352.0 13328.42.92.0134.651352.0 13328.92 12.6616C28.1109 12,7229 28,1161 12,7799 28,121 12.8346C28.1256 12,8854 28,1301 12,9342 28,1301 12.983C28.1301 14,4373 27,2502 15,2321 25,777 15.2321C24.8349 15,2321 24,1352 14,9821 23,5661 14.7787C23.176 14,6393 22,8472 14,5218 22,5437 14.5218C21.7977 14,5218 21,2429 15,0123 21,2429 15.6887C21 .2429 16.7375 22.9072 17.6335 25.6622 17.6335ZM24.1317 9.27932C24.1317 7.94324 24.9928 7.09766 26.1024 7.09766C27.2119 7.09766 28.0918 7.94324 28.0918 9.27932C28.0918 10.6321 27.2311 11.5321176 9.27932C28.0918 10.6321 27.2311 11.5113176 9.6116 24.106 26.10 u003cpath d = \ "M16.8045 11.9512C16.8045 13.2535 17.2637 13.8962 18.2965 13.8962C19.3298 13.8962 19.8079 13.2535 19.8079 11.9512V8.12928C19.8079 5.82936 18,4879 4,62866 16,4027 4,62866C15,1594 4,62866 14,279 4,98375 13,3609 5,88013C12,653 5,05154 11,6581 4,62866 10,3573 4,62866C9,34336 4,62866 8,57809 4,89931 7,9466 5,5079C7,58314 4,9328 7,105078,000662325 6,566 6,566 4,662 5.47873 13.8962 6.51203 13.8962C7.54479 13.8962 8.0232 13.2535 8.0232 11.9512V8.90741C8.0232 7.58817 8.44431 6.91179 9.53458 6.91179C10.5104 6.91179 10.893 7.58817 10.893 8.94108V11.9512315.893 7.58817 10.893 8.94108V11.95123158119.893 11.9512315.89 90741C13.9157 7.58817 14.3365 6.91179 15.4269 6.91179C16.4027 6.91179 16.8045 7.58817 16.8045 8.94108V11.9512Z \ "/ \ u003e \ u003cpath d = \" M3.31675 6.59049C3.31675 5.28821 2.8386613494,6623235 V11.9512C0.313354 13.2535 0.791758 13.8962 1.82471 13.8962C2.85798 13.8962 3.31675 13.2535 3.31675 11.9512V6.59049Z \ "/> \ u003cpath d = \" M1.87209 0.400291C0.843612 0.400291 0 1.1159 0 1.98861C0 2.87869 0.822846 3.57676 1.87209 3.57676C2.90056 3.57676 3.7234 2.87869 3.7234 1.98861C3.7234 1.1159 2.90056 0.400291 1.87209 0.400291Z \ "fill = \" # 1BB76E \ "/ \ u003c / s \ u003c3 / u003c > ",
contentPolicyHtml: "Вклады пользователей под лицензией \ u003ca href = \" https: //stackoverflow.com/help/licensing \ "\ u003ecc by-sa \ u003c / a> \ u003ca href = \" https://stackoverflow.com / legal / content-policy \ "> (политика содержания) \ u003c / a>",
allowUrls: true
},
onDemand: правда,
discardSelector: ".discard-answer"
, немедленноShowMarkdownHelp: true, enableTables: true, enableSnippets: true
});
}
});
Спасибо за ответ на Stack Overflow!
Обязательно ответьте на вопрос. Предоставьте подробную информацию и поделитесь своим исследованием!
Но избегайте…
Просить о помощи, разъяснениях или отвечать на другие ответы.
Делать заявления, основанные на мнении; подкрепите их рекомендациями или личным опытом.
Чтобы узнать больше, ознакомьтесь с нашими советами по написанию отличных ответов.
Черновик сохранен
Черновик отклонен
Зарегистрируйтесь или войдите под своим ником
StackExchange.ready (функция () {
StackExchange.helpers.onClickDraftSave ('# ссылка для входа');
});
Зарегистрируйтесь с помощью Google
Зарегистрируйтесь через Facebook
Зарегистрируйтесь, используя электронную почту и пароль
Представлять на рассмотрение
Опубликовать как гость
Имя
Электронное письмо
Обязательно, но не отображается
StackExchange.ready (
function () {
StackExchange.openid.initPostLogin ('. New-post-login', 'https% 3a% 2f% 2fstackoverflow.com% 2fquestions% 2f64950463% 2fhow-do-rxswift-Operators-effect-resubscribes% 23new-answer', 'question_page' );
}
);
Опубликовать как гость
Имя
Электронное письмо
Обязательно, но не отображается
Разместите свой ответ
Отказаться
Нажимая «Опубликовать ответ», вы соглашаетесь с нашими условиями обслуживания, политикой конфиденциальности и политикой использования файлов cookie.
Не тот ответ, который вы ищете? Посмотрите другие вопросы с метками ios swift5 rx-swift или задайте свой вопрос.